package com.lg.consumer;


import com.lg.rocketmq.annotation.MQConsumer;
import com.lg.rocketmq.base.AbstractMQPushConsumer;

import java.util.Map;


/**
 *
 */
@MQConsumer(consumerGroup = "consumerTest", topic = "TopicTest", tag = "Hello")
public class DemoConsumer extends AbstractMQPushConsumer<String> {
	@Override
	public boolean process(String message, Map<String, Object> extMap) {
		System.out.println(message);
		return true;
	}
}
